import org.apache.flink.api.common.functions.MapFunction;

/**
 * @author wangbh
 * @Description: test
 * @date 2021/7/23 14:28
 */
public class IncrementMapFunction implements MapFunction<Long, Long> {
    @Override
    public Long map(Long record) throws Exception {
        return record + 1;
    }
}
